package org.alex.mqtt.common.protocol;

import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.mqtt.MqttMessage;

/**
 * mqtt处理器
 * @author : alex
 */
public interface MqttProcessor {

    /**
     * mqtt请求处理
     */
    void processRequest(ChannelHandlerContext ctx, MqttMessage mqttMessage);
}
